3de0a5c94ef273850d417031ed23d816655c138f,code/src/main/java/com/googlecode/cqengine/TransactionalIndexedCollection.java,TransactionalIndexedCollection,retrieve,#Query#QueryOptions#,358

Before Change


    public ResultSet<O> retrieve(Query<O> query, QueryOptions queryOptions) {
        if (isIsolationLevel(queryOptions, READ_UNCOMMITTED)) {
            // Allow the query to read directly from the collection with no filtering overhead...
            return new CloseableFilteringResultSet<O>(super.retrieve(query, queryOptions), query, queryOptions) {
                @Override
                public boolean isValid(O object, QueryOptions queryOptions) {
                    return true;

After Change


    public ResultSet<O> retrieve(Query<O> query, QueryOptions queryOptions) {
        if (isIsolationLevel(queryOptions, READ_UNCOMMITTED)) {
            // Allow the query to read directly from the collection with no filtering overhead...
            return super.retrieve(query, queryOptions);
        }
        // Otherwise apply READ_COMMITTED isolation...